<?php

require_once __DIR__.'/vendor/autoload.php';

// 连接 rabbitmq 服务器
$connection = new \PhpAmqpLib\Connection\AMQPStreamConnection('127.0.0.1', 5672, 'guest', 'guest');

// 获取生产者对象
$producer = new \App\Producer($connection);

// 简单模式和工作模式
// $producer->helloWorld();

// 发布/订阅模式
// $producer->publishSubscribe();

// 路由模式
// $producer->routing();

// 主题模式
// $producer->topic();

// rpc
$producer->rpc();

// 关闭连接
$connection->close();